package com.zdxk.msgPush.common.rocket.consume;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

public interface IMsgHandler {

    void dealMsg(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext);
}
